6b13b245a296daea04e424bbddd473eaeeebc49c,bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/tasks/UpgradeTask.java,UpgradeTask,moveJobFromPreviousVersion,#Resource#,187
Before Change
final List<InstanceDescription> potentialTargets = caps.getPotentialTargets("/", null);
String targetId = null;
if ( potentialTargets != null && potentialTargets.size() > 0 ) {
final QueueInfo info = configuration.getQueueConfigurationManager().getQueueInfo(topic);
logger.debug("Found queue {} for {}", info.queueConfiguration, topic);
targetId = caps.detectTarget(topic, vm, info);
if ( targetId != null ) {
After Change
final Map<String, Object> properties = ResourceHelper.cloneValueMap(vm);
properties.put(JobImpl.PROPERTY_BRIDGED_EVENT, true);
final String topic = (String)properties.remove("slingevent:topic");
properties.put(ResourceHelper.PROPERTY_JOB_TOPIC, topic);
properties.remove(Job.PROPERTY_JOB_QUEUE_NAME);
properties.remove(Job.PROPERTY_JOB_TARGET_INSTANCE);
// and binary properties
properties.putAll(binaryProperties);
properties.remove("slingevent:properties");
if ( !properties.containsKey(Job.PROPERTY_JOB_RETRIES) ) {
properties.put(Job.PROPERTY_JOB_RETRIES, 10); // we put a dummy value here; this gets updated by the queue
}
if ( !properties.containsKey(Job.PROPERTY_JOB_RETRY_COUNT) ) {
properties.put(Job.PROPERTY_JOB_RETRY_COUNT, 0);
}
final List<InstanceDescription> potentialTargets = caps.getPotentialTargets("/", null);
String targetId = null;
if ( potentialTargets != null && potentialTargets.size() > 0 ) {
final QueueConfigurationManager qcm = configuration.getQueueConfigurationManager();
if ( qcm == null ) {
resolver.revert();
return;
}
final QueueInfo info = qcm.getQueueInfo(topic);
logger.debug("Found queue {} for {}", info.queueConfiguration, topic);
targetId = caps.detectTarget(topic, vm, info);
if ( targetId != null ) {